package com.juc.completionService.completionService4;

import java.util.concurrent.Callable;


/**
 *  Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException;
 * 等待指定的timeout时间之内获取到值时立即向下继续执行，如果超时也立即向下执行
 *
 */
public class MyCallableA implements Callable<String>{

	@Override
	public String call() throws Exception {
		Thread.sleep(5000);
		System.out.println("MyCallableA " + System.currentTimeMillis());
		return "returneA";
	}

}
